package org.bigwinner.flinkLearning.Constants;

import org.bigwinner.flinkLearning.utils.ConfigFileUtils;

/**
 * @author: IT大狮兄
 * @date: 2021/8/1 上午9:44
 * @version: 1.0.0
 * @description: 常量类
 */
public class ConstantsValue {
    /** MySQL相关常量 **/
    public static final String MYSQL_DRIVER = ConfigFileUtils.getValue("mysql.driver");
    public static final String MYSQL_URL = ConfigFileUtils.getValue("mysql.url");
    public static final String MYSQL_USER = ConfigFileUtils.getValue("mysql.user");
    public static final String MYSQL_PASS = ConfigFileUtils.getValue("mysql.password");
    public static final String MYSQL_TABLE = ConfigFileUtils.getValue("mysql.tb");

    /** KAFKA相关常量 **/
    public static final String KAFKA_BOOTSTRAP_SERVERS = ConfigFileUtils.getValue("kafka.bootstrap.servers");
    public static final String KAFKA_GROUP_ID = ConfigFileUtils.getValue("kafka.group.id");
    public static final String KAFKA_CONSUMER_TOPIC = ConfigFileUtils.getValue("kafka.consumer.topic");

    /** REDIS相关常量 **/
    public static final String REDIS_HOSTS = ConfigFileUtils.getValue("redis.hosts");
    public static final String REDIS_PASSWORD = ConfigFileUtils.getValue("redis.password");

    /** ES相关常量 **/
    public static final String ES_HOSTS = ConfigFileUtils.getValue("es.hosts");
    public static final String ES_CLUSTER_NAME = ConfigFileUtils.getValue("es.cluster.name");
    public static final String ES_USER_NAME = ConfigFileUtils.getValue("es.user.name");
    public static final String ES_USER_PASSWORD = ConfigFileUtils.getValue("es.user.password");
    public static final String ES_INDEX_SUCCESS = ConfigFileUtils.getValue("es.table.success");
    public static final String ES_INDEX_FAIL = ConfigFileUtils.getValue("es.table.fail");
    public static final String ES_INDEX_NOPATTERN = ConfigFileUtils.getValue("es.table.nopattern");
    public static final String ES_PROFILE = ConfigFileUtils.getValue("es.profile");
}
